package com.omuao.message.queue.core.queue;

/**
 * @author Administrator
 */
public interface DelayQueue {

    /**
     * 提交消息
     *
     * @param message 消息
     */
    void commit(String message);

    /**
     * 提交消息
     *
     * @param id      主键
     * @param message 消息
     */
    void commit(String id, String message);

    /**
     * 提交消息
     *
     * @param message   消息
     * @param timestamp 时间戳
     */
    void commit(String message, Long timestamp);

    /**
     * 提交消息
     *
     * @param id        主键
     * @param message   消息
     * @param timestamp 时间戳
     */
    void commit(String id, String message, Long timestamp);


}
